package top.ucat.boots.example.rocketmq.provider.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Auther: Jun
 * @Date: 2019/8/21 15:28
 * @Description:
 */
public interface MySource {

    @Output("output")
    MessageChannel output();

    @Input("input")
    SubscribableChannel input();

}
